--[[
    编码: JX-67-10
    名称: 站台货品明细-呼出空料箱
    作者：HAN  
    日期：2025-3-10

    级别：项目
    
    函数： RunEmptyBoxOutProcess

    功能:
        -- 后台脚本计算入库需要呼出多少空料箱

    更改记录:
        V3.0 HAN 20241231 改成后台线程来处理空料箱呼出计算，因为这个过程是一个比较长的事务，有并发锁表的风险
                          本次改进的目的就是将这些长事务统一交给后台一个线程排队处理
--]]

require ("jx_emptyboxoutplan")

--[[ 

datajson 格式: 
    paramter = {
        station = station,
        login = strUserLogin,
        user_name = strUserName,
        bs_type = "".
        bs_no = ""
    } 
]]

function RunEmptyBoxOutProcess ( strLuaDEID ) 
    local nRet, strRetInfo, n
    local paramter, data_json
    local result = { cntr_count = 0 }
    
    nRet, paramter = m3.GetSysDataJson( strLuaDEID )
    if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), data_json ) end
       
    -- 从入库单这里获取 仓库、库区编码，如果不一样报错
    local station = lua.Get_StrAttrValue( paramter.station )
    local bs_type = lua.Get_StrAttrValue( paramter.bs_type )
    local bs_no = lua.Get_StrAttrValue( paramter.bs_no )

    if ( bs_type ~= "Inbound_Wave" ) then
        mobox.stopProgram( strLuaDEID,  "站台货品明细的来源目前只支持入库波次!")
        return 1
    end        
    if ( bs_no == "" ) then
        mobox.stopProgram( strLuaDEID,  "入库波次号不能为空!")
        return 1
    end 

    local in_wave
    nRet, in_wave = m3.GetDataObjectByKey(strLuaDEID, "Inbound_Wave", "S_WAVE_NO", bs_no )
    if ( nRet ~= 0 or in_wave == "") then 
        mobox.stopProgram( strLuaDEID,  "无效的入库波次编码'"..bs_no.."'" )
        return 1
    end 

    local wh_code = lua.Get_StrAttrValue( in_wave.wh_code )
    local area_code = lua.Get_StrAttrValue( in_wave.area_code )
    if ( wh_code == '' ) then
        mobox.stopProgram( strLuaDEID, "入库波次对象中仓库属性不能为空!" )
        return  1
    end 
    if ( area_code == '' ) then
        mobox.stopProgram( strLuaDEID, "入库波次对象中库区属性不能为空!" )
        return  1
    end    

    -- 获取需要入库的货品明细，合并相同货品编码
    local strCondition
    local data_objs

    -- 要联表查询的表
    local strTable = "TN_Station_Goods_Detail a LEFT JOIN TN_Material b ON a.S_ITEM_CODE = b.S_ITEM_CODE" 
    -- 要查询的属性
    local strAttrs = "a.S_ITEM_CODE, a.S_ITEM_NAME, a.F_QTY, b.F_WEIGHT, b.F_VOLUME, b.S_CELL_TYPE" 

    strCondition = "a.S_STATION_NO = '"..station.."' AND a.N_B_STATE = 0 AND a.S_BS_TYPE = '"..bs_type.."' AND a.S_BS_NO = '"..bs_no.."'"
    nRet, strRetInfo = mobox.queryMultiTable(strLuaDEID, strAttrs, strTable, 1000, strCondition )
    if ( nRet ~= 0 ) then return 2, "queryMultiTable 失败!"..strRetInfo end
    if ( strRetInfo == '' ) then 
        mobox.stopProgram( strLuaDEID, "没找到需要入库的站台货品!" )
        return  1
    end
    
    local n, item_code, qty, weight, volume, cell_type
    local detail_attrs
    local bFind
    local sg_detail_list = {}       -- 站台货品明细
    local ret_data = json.decode(strRetInfo)

    for n = 1, #ret_data do
        item_code = lua.Get_StrAttrValue( ret_data[n][1] )
        item_name = lua.Get_StrAttrValue( ret_data[n][2] )        
        qty = lua.Get_NumAttrValue( ret_data[n][3] )    
        weight = lua.Get_NumAttrValue( ret_data[n][4] ) 
        volume = lua.Get_NumAttrValue( ret_data[n][5] )         
        cell_type = lua.Get_StrAttrValue( ret_data[n][6] )  

        if ( item_code ~= '' and qty > 0 ) then
            bFind = false
            for m = 1, #sg_detail_list do
                if (sg_detail_list[m].item_code == item_code) then
                    bFind = true
                    sg_detail_list[m].qty = sg_detail_list[m].qty + qty
                    break
                end
            end
            if ( bFind == false ) then
                local sg_detail = {
                    item_code = item_code,
                    item_name = item_name,
                    qty = qty,
                    weight = weight,
                    volume = volume,
                    cell_type = cell_type
                }
                table.insert( sg_detail_list, sg_detail )
            end
        end
    end    
    
    -- 计算货品件数,种类
    local total_qty = 0
    local good_type_num = #sg_detail_list

    if ( good_type_num == 0 ) then
        result = { cntr_count = 0 }
        mobox.returnValue( strLuaDEID, 1, lua.table2str(result) )
        return 0
    end

    for n = 1, good_type_num do
        total_qty = total_qty + sg_detail_list[n].qty
    end

    local item_list = {}    -- 需要入库的货品
    local obj_attrs

    -- 生成要入库的货品链表 item_list
    for n = 1, good_type_num do
        local item = {
            item_code = sg_detail_list[n].item_code,
            item_name = sg_detail_list[n].item_name,
            row = n,
            volume = sg_detail_list[n].volume,
            weight = sg_detail_list[n].weight,
            cell_type = sg_detail_list[n].cell_type,
            qty = sg_detail_list[n].qty,
            alloc_qty = 0,
            cntr_cell_list = {},
            empty_cell_type = "",
            upgrad_cell_index = 0,          -- 标记货品开始升格的料格 A = 1, B = 2 ，如果到A还没有合适料格，要从这个料格开始降格
            Q = 0,
            ok = false                      -- true 表示这个货品已经分配好入库料箱
        }
        table.insert( item_list, item )
    end
  
    lua.Debug( strLuaDEID, debug.getinfo(1), "超重货品 item_list-->", item_list )

    -- 呼出空料箱算法
    local ps_cntr_list = {}
    local ps_detail_list = {}    
    local lane = ""             -- 可用巷道

    nRet, lane = jx_base.Get_Available_Lane( strLuaDEID, area_code )
    if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), 'jx_base.Get_Available_Lane!'..lane ) end
    if ( lane == '' ) then
        mobox.stopProgram( strLuaDEID,  "库区里的所有堆垛机状态都是不可用，无法继续呼出料箱!")
        return 1
    end       

    nRet, strRetInfo = JX_EmptyBoxCellOutPlan( strLuaDEID, item_list, wh_code, area_code, lane, station, bs_type, bs_no, ps_cntr_list, ps_detail_list )  
    if ( nRet ~= 0 ) then
        if (nRet == 1) then
            mobox.stopProgram( strLuaDEID,  strRetInfo)
            return 1
        else
            lua.Error( strLuaDEID, debug.getinfo(1), "JX_EmptyBoxCellOutPlan错误: "..strRetInfo)
        end
    end    

    -- 站台货品明细 的状态改成 处理中
    strCondition = "S_STATION_NO = '"..station.."' AND S_BS_TYPE = '"..bs_type.."' AND S_BS_NO = '"..bs_no.."'"
    local strSetAttr = "N_B_STATE = 1"        -- 1  处理中
    nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Station_Goods_Detail", strCondition, strSetAttr )
    if ( nRet ~= 0 ) then  lua.Error( strLuaDEID, debug.getinfo(1), "更新【站台货品明细】信息失败!"..strRetInfo ) end 


    result = { 
        cntr_count = #ps_cntr_list,
        cntr_cell_list = ps_detail_list,
        wave_obj_id = in_wave.id
    }
    mobox.returnValue( strLuaDEID, 1, lua.table2str(result) )

    return 0
end